package com.xiaoze.function;

import com.xiaoze.bean.WaterSensor;
import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author 小泽
 * @create 2024-09-02  15:07
 * 记得每天敲代码哦
 */
public class MyMapFunctionImpl implements MapFunction<WaterSensor,String> {
       @Override
       public String map(WaterSensor value) throws Exception {
              return value.getId();
       }
}
